package io.github.talelin.sleeve.service.Impl;

import io.github.talelin.sleeve.module.kafka.KafkaProducer;
import io.github.talelin.sleeve.module.kafka.KafkaProducerTest;
import io.github.talelin.sleeve.service.KafkaTestService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class KafkaTestServiceImpl implements KafkaTestService {

    @Resource
    private KafkaProducerTest kafkaProducerTest;

    @Override
    public void testKafka(String message) {
        kafkaProducerTest.pushKafkaTest(message);
    }
}
